[FLINK-38899][runtime-web] Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled by och5351 · Pull Request #27874 · apache/flink

och5351 · 2026-04-01T08:18:54Z

What is the purpose of the change

[FLINK-38899][runtime-web] Introduce the Rescales/History sub-page for streaming jobs with the adaptive scheduler enabled
The pr is not blocked by FLIP-495 completion and is independent sub-task in FLIP-487.

Brief change log

Adds the 'Rescales/History' tab and 'HistoryDetail' subpage in relation to [FLINK-38897][Runtime/REST] Introduce /jobs/:jobid/rescales/config endpoint to REST API #27580.

Dependent PRs

[FLINK-38894][runtime/rest] Introduce the /jobs/:jobid/rescales/history endpoint in the REST API #27705

[FLINK-38895][runtime] Introduce the /jobs/:jobid/rescales/details/:rescaleuuid endpoint in the REST API #27695

Rescales History Tab

Rescales HistoryDetail page

Verifying this change

Reference
#27826

Does this pull request potentially affect one of the following parts:

Dependencies (does it add or upgrade a dependency): (yes / no)
The public API, i.e., is any changed class annotated with @Public(Evolving): (yes / no)
The serializers: (yes / no / don't know)
The runtime per-record code paths (performance sensitive): (yes / no / don't know)
Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: (yes / no / don't know)
The S3 file system connector: (yes / no / don't know)

Documentation

Does this pull request introduce a new feature? (yes / no)
If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)

flinkbot · 2026-04-01T08:27:25Z

CI report:

5c9edc7 Azure: SUCCESS

Bot commands

The @flinkbot bot supports the following commands:

@flinkbot run azure re-run the last Azure build

RocMarshal

Hi, @och5351 Thank you for your hard work.

LGTM on the whole, just a few of comments.
PTAL in your free time :)

och5351 · 2026-04-02T23:48:31Z

Hi, @RocMarshal !
Could you please review this one more time?

Thank you.

fe05b76

RocMarshal · 2026-04-03T16:02:02Z

I checked UI of the PR locally with #27705.

checked:

Refresh button related logic and correctness
Rescales page showing logic
The table basic information showing logic, like tooltip, table headers, columns...,etc.

LGTM +1 on the whole just a few of issues:

highlighted in the Fig.

When I click the Rescales/History from Rescales/Configuration page, the new Rescales/History page did not request the /jobs/:jobid/rescales/history interface， We expect that in this case, the corresponding API can be requested again.

Thanks @och5351 for the hard work.
I conducted some manual tests locally and found some minor issues, PTAL next week:)

och5351 · 2026-04-06T03:00:59Z

I checked UI of the PR locally with #27705.

checked:

Refresh button related logic and correctness

Rescales page showing logic

The table basic information showing logic, like tooltip, table headers, columns...,etc.

LGTM +1 on the whole just a few of issues:

highlighted in the Fig.

When I click the Rescales/History from Rescales/Configuration page, the new Rescales/History page did not request the /jobs/:jobid/rescales/history interface， We expect that in this case, the corresponding API can be requested again.

Thanks @och5351 for the hard work. I conducted some manual tests locally and found some minor issues, PTAL next week:)

Hi, @RocMarshal !
Thank you for your review.

Could you please review this again?

While waiting

Done

While waiting : 6f8d480
Refresh : 3824aab

I have a question: does the Acquired Parallelism and Acquired Slots tab also apply hyphens while waiting?

RocMarshal · 2026-04-06T10:02:44Z

When I click the Rescales/History from Rescales/Configuration page, the new Rescales/History page did not request
the /jobs/:jobid/rescales/history interface， We expect that in this case, the corresponding API can be requested again.

Thanks @och5351 for the quick updated.
I rechecked this scenario, and it doesn’t seem to be taking effect.
I’d like to confirm—does the behavior of the refresh button here follow any reference from other pages?

I have a question: does the Acquired Parallelism and Acquired Slots tab also apply hyphens while waiting?

That's a good catch, reasonable!

RocMarshal

Thanks @och5351 for the update
I'll merge it after the REST API related PRs ready and no more comments from other reviewers.

och5351 · 2026-04-07T02:33:02Z

Thanks @och5351 for the update I'll merge it after the REST API related PRs ready and no more comments from other reviewers.

Thank you, @RocMarshal!
I will merge all commits into one.

RocMarshal · 2026-04-08T09:05:36Z

+        </tr>
+      </thead>
+      <tbody>
+        <ng-container *ngFor="let history of rescalesHistories; trackBy: trackById">


history -> jobRescaleDetails

Hi, @RocMarshal !
I submit a new commit now. Could you please confirm it one more time?

RocMarshal · 2026-04-08T09:06:07Z

 })
 export class JobRescalesComponent implements OnInit, OnDestroy {
-  public rescalesConfig?: RescalesConfig;
+  public rescalesHistories?: RescalesHistory;


rescalesHistories -> rescalesHistory

RocMarshal · 2026-04-08T09:06:30Z

+    return item.rescaleUuid;
+  }
+
+  public onExpandChange(history: BriefJobRescaleDetails, expanded: boolean): void {


history -> jobRescaleDetails

och5351 · 2026-04-09T01:55:37Z

  }

  public refresh(): void {
+    const expandedUuids = Array.from(this.expandedRowsSet);


@RocMarshal
It seemed that the details section (e.g., acquirePrallelism) was not updating even after clicking the refresh button, so I have added some content.

Could you please confirm this change?

Thanks @och5351
I'll have check before the next review/approve

RocMarshal · 2026-04-09T05:03:42Z

        takeUntil(this.destroy$)
      )
-      .subscribe(([config]) => {
+      .subscribe(([histories, config]) => {


histories -> history

…r streaming jobs with the adaptive scheduler enabled Co-authored-by: Matthias Pohl <mpohl@confluent.io> Co-authored-by: Yuepeng Pan <hipanyuepeng@gmail.com>

… when the schedulerExecutionMode variable value is null Co-authored-by: Matthias Pohl <mpohl@confluent.io> Co-authored-by: Yuepeng Pan <hipanyuepeng@gmail.com>

RocMarshal · 2026-04-11T11:39:52Z

Thanks @och5351 , merged.

RocMarshal self-assigned this Apr 1, 2026

RocMarshal requested changes Apr 1, 2026

View reviewed changes

RocMarshal reviewed Apr 3, 2026

View reviewed changes

Comment thread flink-runtime-web/web-dashboard/src/app/interfaces/job-rescales.ts Outdated

RocMarshal requested changes Apr 3, 2026

View reviewed changes

och5351 force-pushed the FLINK-38899 branch from 8ebd77f to d1843bc Compare April 3, 2026 03:23

och5351 requested a review from RocMarshal April 3, 2026 03:33

och5351 force-pushed the FLINK-38899 branch from 5396e60 to 6f8d480 Compare April 6, 2026 02:44

och5351 force-pushed the FLINK-38899 branch from de5f2b9 to a52050f Compare April 7, 2026 01:44

RocMarshal approved these changes Apr 7, 2026

View reviewed changes

och5351 force-pushed the FLINK-38899 branch from a52050f to f2f4915 Compare April 7, 2026 02:33

RocMarshal requested changes Apr 8, 2026

View reviewed changes

och5351 force-pushed the FLINK-38899 branch from 7aecdac to 4d8f2e5 Compare April 9, 2026 01:51

och5351 commented Apr 9, 2026

View reviewed changes

och5351 force-pushed the FLINK-38899 branch 3 times, most recently from 2cb11c6 to 8181ed2 Compare April 9, 2026 02:14

RocMarshal reviewed Apr 9, 2026

View reviewed changes

github-actions bot added the community-reviewed PR has been reviewed by the community. label Apr 9, 2026

och5351 force-pushed the FLINK-38899 branch 2 times, most recently from fee5f2e to 3f2e7c7 Compare April 9, 2026 10:53

[FLINK-38899][runtime-web] Introduce the Rescales/History sub-page fo…

a59d738

…r streaming jobs with the adaptive scheduler enabled Co-authored-by: Matthias Pohl <mpohl@confluent.io> Co-authored-by: Yuepeng Pan <hipanyuepeng@gmail.com>

och5351 force-pushed the FLINK-38899 branch from d39aacd to a59d738 Compare April 11, 2026 06:25

[hotfix][runtime-web] Handle hyphen in the rescales/configuration tab…

5c9edc7

… when the schedulerExecutionMode variable value is null Co-authored-by: Matthias Pohl <mpohl@confluent.io> Co-authored-by: Yuepeng Pan <hipanyuepeng@gmail.com>

och5351 force-pushed the FLINK-38899 branch from 9b3010a to 5c9edc7 Compare April 11, 2026 06:28

RocMarshal merged commit 451372a into apache:master Apr 11, 2026

Conversation

och5351 commented Apr 1, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

What is the purpose of the change

Brief change log

Rescales History Tab

Rescales HistoryDetail page

Verifying this change

Does this pull request potentially affect one of the following parts:

Documentation

Uh oh!

flinkbot commented Apr 1, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

CI report:

Uh oh!

RocMarshal left a comment

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

Uh oh!

och5351 commented Apr 2, 2026

Uh oh!

Uh oh!

RocMarshal commented Apr 3, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

och5351 commented Apr 6, 2026 • edited by RocMarshal Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

While waiting

Done

Uh oh!

RocMarshal commented Apr 6, 2026

Uh oh!

RocMarshal left a comment

Choose a reason for hiding this comment

Uh oh!

och5351 commented Apr 7, 2026

Uh oh!

RocMarshal Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

och5351 Apr 9, 2026

Choose a reason for hiding this comment

Uh oh!

RocMarshal Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

RocMarshal Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

och5351 Apr 9, 2026

Choose a reason for hiding this comment

Uh oh!

RocMarshal Apr 9, 2026

Choose a reason for hiding this comment

Uh oh!

RocMarshal Apr 9, 2026

Choose a reason for hiding this comment

Uh oh!

RocMarshal commented Apr 11, 2026

Uh oh!

Reviewers

Assignees

Labels

Projects

Milestone

Development

Uh oh!

3 participants

och5351 commented Apr 1, 2026 •

edited

Loading

flinkbot commented Apr 1, 2026 •

edited

Loading

RocMarshal commented Apr 3, 2026 •

edited

Loading

och5351 commented Apr 6, 2026 •

edited by RocMarshal

Loading